package main

import (
	"fmt"
	"log"
)

func main() {
	Init()
	// 订阅全部消息
	pubSub := CacheDBClient.Subscribe("name")
	// 等待消息返回，原因是上一个方法不是立即返回的，囧
	_, err := pubSub.Receive()
	if err != nil {
		fmt.Println(err.Error())
	}
	// 用管道来接收消息
	ch := pubSub.Channel()

	// 处理消息
	for msg := range ch {
		log.Println(msg.Channel, ":", msg.Payload)
	}
}
